package com.example.api.common.message;

import lombok.Data;
import java.io.Serializable;

@Data
public class KafkaMessage<T> implements Serializable {
    private static final long serialVersionUID = 1L;
    
    private String traceId;
    private T data;
    
    public static <T> KafkaMessage<T> of(T data) {
        KafkaMessage<T> message = new KafkaMessage<>();
        message.setData(data);
        return message;
    }
} 